package com.ass.rocketmq.consumer;

import org.apache.rocketmq.client.consumer.DefaultLitePullConsumer;
import org.apache.rocketmq.client.consumer.PullResult;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.message.MessageQueue;

public class DefaultLitePullConsumerTest {

    public static void main(String[] args) throws MQClientException {
        DefaultLitePullConsumer consumer = new DefaultLitePullConsumer("YourConsumerGroup");
        consumer.setNamesrvAddr("127.0.0.1:9876");
// 设置其他属性和订阅关系

        consumer.start(); // 启动消费者




    }
}
